dd3006686fb35721e494fc9d9a21371cb7547cea,performance/src/main/java/com/continuuity/performance/runner/LoggingPerformanceTest.java,LoggingPerformanceTest,testApp,#,18
Before Change
BenchmarkRuntimeMetrics sourceFlowletMetrics = BenchmarkRuntimeStats.getFlowletMetrics("LoggingApp", "LoggingFlow",
"source");
System.out.println("Number of events generated by source flowlet = " + sourceFlowletMetrics.getProcessed());
sourceFlowletMetrics.waitForProcessed(numEvents, 120, TimeUnit.SECONDS);
System.out.println("Number of events generated by source flowlet = " + sourceFlowletMetrics.getProcessed());
BenchmarkRuntimeMetrics loggerFlowletMetrics = BenchmarkRuntimeStats.getFlowletMetrics("LoggingApp", "LoggingFlow",
"logger");
System.out.println("Number of events processed by logger flowlet = " + loggerFlowletMetrics.getProcessed());
loggerFlowletMetrics.waitForProcessed(numEvents, 120, TimeUnit.SECONDS);
System.out.println("Number of events processed by logger flowlet = " + loggerFlowletMetrics.getProcessed());
} finally {
applicationManager.stopAll();
After Change
BenchmarkRuntimeMetrics sourceFlowletMetrics = BenchmarkRuntimeStats.getFlowletMetrics("LoggingApp",
"LoggingFlow", "source");
System.out.println(String.format("Number of events generated by source flowlet = %d",
sourceFlowletMetrics.getProcessed()));
sourceFlowletMetrics.waitForProcessed(numEvents, 120, TimeUnit.SECONDS);
System.out.println(String.format("Number of events generated by source flowlet = %d",
sourceFlowletMetrics.getProcessed()));
BenchmarkRuntimeMetrics loggerFlowletMetrics = BenchmarkRuntimeStats.getFlowletMetrics("LoggingApp",
"LoggingFlow", "logger");
System.out.println(String.format("Number of events processed by logger flowlet = %d",
loggerFlowletMetrics.getProcessed()));
loggerFlowletMetrics.waitForProcessed(numEvents, 120, TimeUnit.SECONDS);
System.out.println(String.format("Number of events processed by logger flowlet = %d",
loggerFlowletMetrics.getProcessed()));
} finally {
applicationManager.stopAll();